#!/usr/bin/env python
from install import *
from files import *
import threading


class myThread(threading.Thread):
    def __init__(self,cm_host,Clustername,Servicetype,Ip):
        threading.Thread.__init__(self)
        self.cm_host = cm_host
        self.clustername = Clustername
        self.servicetype=Servicetype
        self.servicename = 'DATANODE'
        self.ip = Ip

    def run(self):
        print "Starting " + self.ip
        InStall(self.cm_host,self.clustername,self.servicetype,self.ip).cmagentinstall()
        print "Exiting " + self.ip


